package com.bytetool.agent.channel;

import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * @author zouhuixing
 * @date 2024/3/31
 */
public class MessageChannelServer {

    private static final Queue<Object> queue = new LinkedBlockingQueue<>();

    public static void push(Object message) {
        queue.add(message);
    }

    public static Object pull() {
        return queue.poll();
    }
}
